github.com/jackc/pgx/v5/pgconn.Pipeline.conn (field)
52 uses
github.com/jackc/pgx/v5/pgconn (current package)
pgconn.go#L2262: conn *PgConn
pgconn.go#L2440: conn: pgConn,
pgconn.go#L2468: p.conn.frontend.SendParse(&pgproto3.Parse{Name: name, Query: sql, ParameterOIDs: paramOIDs})
pgconn.go#L2469: p.conn.frontend.SendDescribe(&pgproto3.Describe{ObjectType: 'S', Name: name})
pgconn.go#L2479: p.conn.frontend.SendClose(&pgproto3.Close{ObjectType: 'S', Name: name})
pgconn.go#L2489: p.conn.frontend.SendParse(&pgproto3.Parse{Query: sql, ParameterOIDs: paramOIDs})
pgconn.go#L2490: p.conn.frontend.SendBind(&pgproto3.Bind{ParameterFormatCodes: paramFormats, Parameters: paramValues, ResultFormatCodes: resultFormats})
pgconn.go#L2491: p.conn.frontend.SendDescribe(&pgproto3.Describe{ObjectType: 'P'})
pgconn.go#L2492: p.conn.frontend.SendExecute(&pgproto3.Execute{})
pgconn.go#L2502: p.conn.frontend.SendBind(&pgproto3.Bind{PreparedStatement: stmtName, ParameterFormatCodes: paramFormats, Parameters: paramValues, ResultFormatCodes: resultFormats})
pgconn.go#L2503: p.conn.frontend.SendDescribe(&pgproto3.Describe{ObjectType: 'P'})
pgconn.go#L2504: p.conn.frontend.SendExecute(&pgproto3.Execute{})
pgconn.go#L2514: p.conn.frontend.SendBind(&pgproto3.Bind{PreparedStatement: statementDescription.Name, ParameterFormatCodes: paramFormats, Parameters: paramValues, ResultFormatCodes: resultFormats})
pgconn.go#L2515: p.conn.frontend.SendExecute(&pgproto3.Execute{})
pgconn.go#L2532: p.conn.frontend.Send(&pgproto3.Flush{})
pgconn.go#L2547: p.conn.frontend.SendSync(&pgproto3.Sync{})
pgconn.go#L2560: err := p.conn.flushWithPotentialWriteReadDeadlock()
pgconn.go#L2564: p.conn.asyncClose()
pgconn.go#L2566: p.conn.contextWatcher.Unwatch()
pgconn.go#L2567: p.conn.unlock()
pgconn.go#L2598: if !p.conn.resultReader.closed {
pgconn.go#L2599: _, err := p.conn.resultReader.Close()
pgconn.go#L2717: fieldDescriptions := p.conn.getFieldDescriptionSlice(len(sdFields))
pgconn.go#L2726: pgConn: p.conn,
pgconn.go#L2732: p.conn.resultReader = rr
pgconn.go#L2733: return &p.conn.resultReader, nil
pgconn.go#L2735: p.conn.resultReader = ResultReader{
pgconn.go#L2736: commandTag: p.conn.makeCommandTag(msg.CommandTag),
pgconn.go#L2741: return &p.conn.resultReader, nil
pgconn.go#L2745: p.conn.resultReader.closed = true
pgconn.go#L2764: p.conn.resultReader.closed = true
pgconn.go#L2787: p.conn.resultReader.closed = true
pgconn.go#L2838: p.conn.resultReader = ResultReader{
pgconn.go#L2839: pgConn: p.conn,
pgconn.go#L2842: fieldDescriptions: p.conn.getFieldDescriptionSlice(len(msg.Fields)),
pgconn.go#L2844: convertRowDescription(p.conn.resultReader.fieldDescriptions, msg)
pgconn.go#L2845: return &p.conn.resultReader, nil
pgconn.go#L2850: p.conn.resultReader.closed = true
pgconn.go#L2863: p.conn.resultReader = ResultReader{
pgconn.go#L2864: commandTag: p.conn.makeCommandTag(msg.CommandTag),
pgconn.go#L2868: return &p.conn.resultReader, nil
pgconn.go#L2872: p.conn.resultReader.closed = true
pgconn.go#L2881: msg, err := p.conn.receiveMessage()
pgconn.go#L2884: p.conn.asyncClose()
pgconn.go#L2899: p.conn.asyncClose()
pgconn.go#L2912: p.conn.asyncClose()
pgconn.go#L2914: p.conn.contextWatcher.Unwatch()
pgconn.go#L2915: p.conn.unlock()
pgconn.go#L2926: p.conn.asyncClose()
pgconn.go#L2933: p.conn.asyncClose()
pgconn.go#L2941: p.conn.contextWatcher.Unwatch()
pgconn.go#L2942: p.conn.unlock()